package com.mos.iot.mqtt.listener.annotation;

import com.mos.iot.mqtt.constants.MqttConstants;
import com.mos.iot.mqtt.listener.converter.MessageConverter;
import com.mos.iot.mqtt.listener.converter.impl.MqttJsonMessageConverter;

import java.lang.annotation.*;

@Target({ ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface MqttOutput {

    String clientId() default "";

    String topic();

    int qos() default MqttConstants.DEFAULT_TOPIC_QOS;

    Class<? extends MessageConverter> converter() default MqttJsonMessageConverter.class;
}
